#include "pair.h"
#include <iostream>
#include <thread>
#include <chrono>

int main() {
    PairEndpoint pairEndpoint("tcp://*:5556", true);

    int message_count = 0;
    while (true) {
        pairEndpoint.sendMessage("Message " + std::to_string(++message_count));
        pairEndpoint.receiveMessage(zmq::recv_flags::none);
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }

    return 0;
}